package org.devnation.camel;

import java.io.InputStream;
import java.io.OutputStream;
import org.apache.camel.Exchange;

public interface DataFormat {

    void marshal(Exchange exchange, Object graph, OutputStream stream) throws Exception;

    Object unmarshal(Exchange exchange, InputStream stream) throws Exception;
}

package org.devnation.camel;

import org.apache.camel.builder.RouteBuilder;

public class ExampleRouteBuilder extends RouteBuilder {
    @Override
    public void configure() throws Exception {

        from("amq:queue:quotes")
           .filter().xpath("/quote/product/ = 'widget")
                .bean("QuotesService", "widget")
           .filter().xpath("/quote/product/ = 'gadget")
                .bean("QuotesService","gadget");

    }
}

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xsi:schemaLocation="
       http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
       http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd
    ">
    <bean id="quotesService" class="org.devnation.camel.QuotesService"/>"

    <camelContext  xmlns="http://camel.apache.org/schema/spring">
        <route>
            <from uri="amq:queue:quotes"/>
            <filter>
                <xpath>"/quote/product/ = 'widget"</xpath>
            </filter>
                <bean id="quotesService" method="widget"/>
            <filter>
                <xpath>"/quote/product/ = 'gadget"</xpath>
            </filter>
            <bean id="quotesService" method="gadget"/>
        </route>
    </camelContext>

</beans>

        // start with a 30 day window for the first delayed poll
        String since = "RAW("
                + new SimpleDateFormat(FACEBOOK_DATE_FORMAT).format(
                new Date(System.currentTimeMillis() - TimeUnit.MILLISECONDS.convert(30, TimeUnit.DAYS)))
                + ")";

        from("facebook://searchPosts?reading.limit=10&" +
                "reading.locale=en.US&reading.since=" + since + "&" +
                "consumer.initialDelay=1000&" +
                "consumer.sendEmptyMessageWhenIdle=true&"
                + getOauthParams());

    protected String getOauthParams() {
        return "oAuthAppId=" + properties.get("oAuthAppId") +
                "&oAuthAppSecret=" + properties.get("oAuthAppSecret")
                + (properties.get("oAuthAccessToken") != null
                ? ("&oAuthAccessToken=" + properties.get("oAuthAccessToken")) : "");
    }

consumer.key=rtPyyyyyyyyyyyyyyyyg
consumer.secret=HyoWW3xxxxxxxxxxxxxxxxTuyEz8qrk
access.token=7976eeeeeeeeeeeeeeeeeeeuRmG0IP
access.token.secret=VNtttttttttttttttttg0B8jWGs

        PostUpdate post = new PostUpdate(new URL("http://facebook4j.org"))
                .picture(new URL("http://facebook4j.org/images/hero.png"))
                .name("Facebook4J - A Java library for " +
                        "the Facebook Graph API")
                .caption("facebook4j.org")
                .description("Facebook4J is a Java library" +
                        " for the Facebook Graph API.");

        from("direct:post")
                .setBody().constant(post)
                .to("facebook://postFeed/inBody=postUpdate");

        from("twitter://search?type=polling&delay="
                + delay + "&useSSL=true&keywords="
                + keywords + "&" + getUriTokens())
                .choice()
                   .when().simple("${body.tweet.text} > 'java'")
                      .bean("Service", "push")
                .otherwise()
                      .to(">> Tweets received");

    protected String getUriTokens() {
        return "consumerKey=" + consumerKey
                + "&consumerSecret=" + consumerSecret
                + "&accessToken=" + accessToken
                + "&accessTokenSecret=" + accessTokenSecret;
    }

        Date now = new Date();
        String tweet = "Demo: this is a tweet posted on " + now.toString();

        from("direct:post")
            .setBody().constant(tweet)
            .to("twitter://timeline/user?" + getUriTokens());

String data = "{ " +
    " \"" + "timestamp" + "\" : \"" + formatDate(generateTimeStamp()) + "\"," +
    " \"" + "createdAt" + "\" : \"" + status.getCreatedAt().toString() + "\"," +
    " \"" + "id" + "\" : \"" + status.getId() + "\"," +
    " \"" + "text" + "\" : \"" + status.getText() + '\'' + "\"," +
    " \"" + "isFavorited" + "\" : \"" + status.isFavorited() + "\"," +
    " \"" + "isRetweeted" + "\" : \"" + status.isRetweeted() + "\"," +
    " \"" + "favoriteCount" + "\" : \"" + status.getFavoriteCount() + "\"," +
    " \"" + "inReplyToScreenName" + "\" : \"" + status.getInReplyToScreenName() + '\'' + "\"," +
    " \"" + "geoLocation" + "\" : \"" + status.getGeoLocation() + "\"," +
    " \"" + "place" + "\" : \"" + status.getPlace() + "\"," +
    " \"" + "retweetCount" + "\" : \"" + status.getRetweetCount() + "\"," +
    " \"" + "isoLanguageCode" + "\" : \"" + status.getIsoLanguageCode() + "\"," +
    " \"" + "user" + "\" : \"" + status.getUser().getName() + "\"," +
    " \"" + "country" + "\" : \"" + country + "\"" +
    " }";

  private void init(JSONObject json) throws TwitterException {
  	id = getLong("id", json);
  	source = getUnescapedString("source", json);
  	createdAt = getDate("created_at", json);
  	isTruncated = getBoolean("truncated", json);
  	inReplyToStatusId = getLong("in_reply_to_status_id", json);
  	inReplyToUserId = getLong("in_reply_to_user_id", json);
  	isFavorited = getBoolean("favorited", json);

public class StoreService {

    private static String ES_TYPE = "insight-tweet";
    private static StorageService storageService;

    public static void store(@Header("tweet-full") String data) {
        storageService.store(ES_TYPE, generateTimeStamp(), data);
    }

    public void setStorageService(StorageService storageService) {
        StoreService.storageService = storageService;
    }

<?xml version="1.0" encoding="UTF-8" standalone="no"?>
<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
           xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
           xsi:schemaLocation="
           http://www.osgi.org/xmlns/blueprint/v1.0.0
             http://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd">

    <!-- Service Service used to send tweets to ES Storage, parse JSON -->
    <bean id="helper" class="org.devnation.demo.camel.Service">
        <property name="storageService">
            <reference interface="org.fusesource.insight.storage.StorageService" />
        </property>
    </bean>

</blueprint>

  from("twitter://search?type=polling&delay=" + delay
          + "&useSSL=true&keywords=" + keywords
          + "&" + getUriTokens())
          .routeId("Tweet-Store-WS")
          .delay(5000)

          // We receive the Twitter4J Status that we will use
          // to extract info text, isfavorited, is Retweeted, geolocation, isoLanguageCode, contributors
          // and create A JSON message used later on to store it in ES
          .setHeader("tweet-full").method(Service.class, "getJSONTweet")

          // Message is stored using insight in ElasticSearch
          .bean(Service.class, "store")

public interface SocialMediaMBean {

    /* Attributes */
    void setTweetsCounter(Integer val);
    public Integer getTweetsCounter();

    /* Operations */
    List<String> searchTweets(String keywords) throws TwitterException;
    String userInfo(String id) throws TwitterException;

    public List<String> searchTweets(String keywords) throws TwitterException {
        return twitterService.searchTweets(keywords);
    }

    public void init() {
        try {
            if (objectName == null) {
                objectName = new ObjectName("hawtio:type=SocialMedia");
            }
            if (mBeanServer == null) {
                mBeanServer = ManagementFactory.getPlatformMBeanServer();
            }
            try {
                mBeanServer.registerMBean(this, objectName);
            } catch (InstanceAlreadyExistsException iaee) {
                // Try to remove and re-register
                LOG.info("Re-registering SchemaLookup MBean");
                mBeanServer.unregisterMBean(objectName);
                mBeanServer.registerMBean(this, objectName);
            }
        } catch (Exception e) {
            LOG.warn("Exception during initialization: ", e);
            throw new RuntimeException(e);
        }
    }

<?xml version="1.0" encoding="UTF-8" standalone="no"?>
<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0">

    <cm:property-placeholder id="twitterConfig" persistent-id="twitter"
               update-strategy="reload"/>

    <bean id="twitterFactory" class="org.devnation.demo.service.TwitterFactory">
        <property name="consumerKey" value="${consumer.key}"/>
        <property name="consumerSecret" value="${consumer.secret}"/>
        <property name="accessToken" value="${access.token}"/>
        <property name="accessTokenSecret" value="${access.token.Secret}"/>
    </bean>

    <bean id="twitterService" class="org.devnation.demo.service.TwitterService">
        <property name="twitterFactory" ref="twitterFactory"/>
    </bean>

    <bean id="socialDataMBean" class="org.devnation.demo.service.SocialMedia"
          init-method="init" destroy-method="destroy" scope="singleton">
        <property name="twitterService" ref="twitterService"/>
    </bean>
</blueprint>

<?xml version="1.0" encoding="UTF-8" standalone="no"?>
<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0">

    <bean id="plugin" class="io.hawt.web.plugin.HawtioPlugin" init-method="init" destroy-method="destroy">
        <property name="name" value="${plugin-name}"/>
        <property name="context" value="${plugin-context}"/>
        <property name="domain" value="${plugin-domain}"/>
        <property name="scripts" value="${plugin-scripts}"/>
    </bean>

</blueprint>

        $scope.searchTweets = function () {
            if (Core.isBlank($scope.keywords)) {
                return;
            }
            jolokia.request({
                type: 'exec',
                mbean: SOCIAL.mbean,
                operation: 'searchTweets',
                arguments: [$scope.keywords]
            }, {
                method: 'POST',
                success: function (response) {
                    /* Simple Table */
                    $scope.tweets = response.value.map(function (val) {
                        return { tweet: val };
                    });
                    Core.$apply($scope);
                },
                error: function (response) {
                    SOCIAL.log.warn("Failed to search for Tweets: ", response.error);
                    SOCIAL.log.info("Stack trace: ", response.stacktrace);
                    Core.$apply($scope);
                }

<div class="row-fluid gridStyle" ng-controller="SOCIAL.FormController">
    <h3>Twitter</h3>

    <div class="span12">
        <div>
            <form name="inputForm" ng-submit="searchTweets()">
                <div>
                    Keyword(s) : <input type="text" class="entry-widget" ng-model="keywords">
                </div>
                <p class="span4 centered">
                    <input type="submit" class="btn btn-success" ng-disabled="!keywords" value="Search information">
                </p>
            </form>
        </div>
    </div>

    <div class="span8">
        <div class="gridStyle" ng-grid="tweetsGrid"/>
    </div>

</div>